package org.dragonnova.iot.business.cloud.mq.service;

import org.dragonnova.iot.business.cloud.mq.message.TagMessage;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.transaction.annotation.Transactional;

//@Service
public class TagMessageMqService {

	private final static Logger LOGGER = LoggerFactory
			.getLogger(TagMessageMqService.class);

	// @Autowired
	// private JmsTemplate jmsTemplate;

	// @Autowired
	// private TagJdbcDao tagJdbcDao;

	public void sendMessage(final TagMessage msg) {
		// this.jmsTemplate.convertAndSend(Constants.TAG_QUEUE, msg);
	}

	@Transactional
	public void sendTopicMessage(String jsonText) {
		try {
			// List<THTagValue> values = new ArrayList<>();
			// this.tagJdbcDao.batchInsertTags(values);
			// this.jmsTemplate.convertAndSend(Constants.TAG_FILTER_QUEUE,
			// jsonText);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}
